d5c500d94cd574fd5e55346e7cd46cb4f37cc6c4,hazelcast-client-legacy/src/test/java/com/hazelcast/client/map/ClientMapStoreTest.java,ClientMapStoreTest,mapSize_After_MapStore_OperationQueue_OverFlow_Test,#,114
Before Change
final IMap map = client.getMap(MAP_NAME);
final int max = getMaxCapacity(server) + 1;
for (int i = 0; i < max; i++) {
map.putAsync(i, i);
}
Thread.sleep(1000 * (delaySeconds + 1));
After Change
HazelcastInstance client = hazelcastFactory.newHazelcastClient();
IMap map = client.getMap(MAP_NAME);
int maxCapacity = getMaxCapacity(server);
List<Future> futures = new ArrayList<Future>(maxCapacity * 2);
for (int i = 0; i < maxCapacity * 2; i++) {
Future future = map.putAsync(i, i);
futures.add(future);
}
int success = 0;
for (Future future : futures) {
try {
future.get();
success++;
} catch (ReachedMaxSizeException e) {
//ignore
}